package com.boot.entity.config_canal;

import com.boot.entity.Config;
import lombok.Data;

import java.util.List;

/**
 * 这个类是接收canal发送过来的消息所必须要的
 * @author youzhengjie 2022-09-01 16:55:18
 */
@Data
public class ConfigCanalBean {
    //config实体类的数据
    private List<Config> data;
    //数据库名称
    private String database;
    private long es;
    //递增
    private int id;
    //是否是DDL语句
    private boolean isDdl;
    //表结构的字段类型
    private MysqlType mysqlType;
    //UPDATE语句，旧数据
    private String old;
    //主键名称
    private List<String> pkNames;
    //sql语句
    private String sql;
    //暂时没发现什么用，不过也要写上这个属性
    private SqlType sqlType;
    //表名
    private String table;
    private long ts;
    //(新增)INSERT、(更新)UPDATE、(删除)DELETE、(删除表)ERASE等等
    private String type;
    //getter、setter方法
}

